Micron Document
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
| SparkN0de-git | SparkN0de |
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Node / ReticulumProjects / LXMF.git / commits / b2aba3f


Commit b2aba3f6db59d016afa994604b3d4a85c70ca718

󰉖 Browse tree at this commit

Parents : ece55d1
Author : Mark Qvist <mark@unsigned.io>
Date : 2022-05-17T19:43:51+02:00

Added ignore functionality

Changes

1 files changed, 17 insertions(+), 0 deletions(-)

M LXMF/LXMF.py +17

Diff

diff --git a/LXMF/LXMF.py b/LXMF/LXMF.py
index 9a486f7..a1d2b0f 100644
--- a/LXMF/LXMF.py
+++ b/LXMF/LXMF.py
@@ -843,6 +843,8 @@ class LXMRouter:
self.direct_links = {}
self.delivery_destinations = {}
+ self.ignored_list = []
+
self.processing_outbound = False
self.processing_inbound = False
self.processing_count = 0
@@ -1136,6 +1138,10 @@ class LXMRouter:
message.transport_encrypted = False
message.transport_encryption = None
+ if message.source_hash in self.ignored_list:
+ RNS.log(str(self)+" ignored message from "+RNS.prettyhexrep(message.source_hash), RNS.LOG_DEBUG)
+ return False
+
if self.__delivery_callback != None and callable(self.__delivery_callback):
try:
self.__delivery_callback(message)
@@ -1595,6 +1601,14 @@ class LXMRouter:
RNS.log("Error while removing peer "+RNS.prettyhexrep(peer_id)+". The contained exception was: "+str(e), RNS.LOG_ERROR)
+ def ignore_destination(self, destination_hash):
+ if not destination_hash in self.ignored_list:
+ self.ignored_list.append(destination_hash)
+
+ def unignore_destination(self, destination_hash):
+ if destination_hash in self.ignored_list:
+ self.ignored_list.remove(destination_hash)
+
def fail_message(self, lxmessage):
RNS.log(str(lxmessage)+" failed to send", RNS.LOG_DEBUG)
@@ -1605,6 +1619,9 @@ class LXMRouter:
if lxmessage.failed_callback != None and callable(lxmessage.failed_callback):
lxmessage.failed_callback(lxmessage)
+ def __str__(self):
+ return "<LXMRouter "+RNS.hexrep(self.identity.hash, delimit=False)+">"
+
def process_outbound(self, sender = None):
if self.processing_outbound:
return


──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────